创建主题

您所在的位置:网站首页 rocketmq 创建订阅组 创建主题

创建主题

2024-07-12 06:07| 来源: 网络整理| 查看: 265

场景描述

RocketMQ的主题是消息的逻辑分类单位,用于将消息进行分组和管理。创建主题的场景可以根据具体业务需求来确定,以下是一些常见的场景描述:

消息发布与订阅:当需要实现消息发布与订阅模式时,可以创建一个主题来管理相关的消息。发布者可以将消息发送到该主题,而订阅者可以订阅该主题以接收感兴趣的消息。 事件驱动架构:在事件驱动的架构中,不同的模块之间通过事件进行通信。每个事件可以对应一个主题,模块可以将事件发送到相应的主题,其他模块可以订阅该主题以接收事件通知。 日志收集与分析:当需要收集大量的日志数据并进行分析时,可以创建一个主题来管理日志消息。日志产生者可以将日志消息发送到该主题,而日志消费者可以订阅该主题以进行实时分析或存储。 异步处理:当需要将某些操作异步处理时,可以创建一个主题来管理相关的异步消息。操作发起者可以将异步消息发送到该主题,而异步处理器可以订阅该主题以进行后续的异步处理。 分布式事务消息:在分布式系统中,当需要实现分布式事务消息时,可以创建一个主题来管理相关的事务消息。事务发起者可以将事务消息发送到该主题,而事务消费者可以订阅该主题以进行事务的处理和确认。

总的来说,创建主题的场景可以根据具体的业务需求来确定。主题可以帮助将消息进行逻辑分类和管理,实现不同的消息传递模式和业务场景

新建主题

1、 天翼云官网点击控制中心,选择产品分布式消息服务RocketMQ。

2、 登录分布式消息服务RocketMQ控制台,点击右上角地域选择对应资源池。

3、 进入实例列表,点击【管理】按钮进入管理菜单。

DrEwNtcINJUd_vX_y_raLw.png

4、 进入主题管理菜单,点击【新建主题】按钮

3rOEWzUx5QanRS18sFtB_Q.png

5、 在弹出的新建主题页面,填写如下字段信息

AgAABTXIByUHlrP9oK9LC5vZ24RVS-uJ.png

1)默认展示当前集群名称,不可修改。

2)选择主题所在的Broker,按照实例创建时候选择的主备节点对数列出每个broker,可复选。

3)填写主题名称,名字限制2到64个字符,超过限制会导致创建主题失败,用户创建主题只能包含大小写字母数字以及_和-符号。

4)按照实际需求填写主题备注。

5)填写每个Broker分区数,分区数必须大于0,小于等于8,创建严格顺序队列时,设置分区数为1,且只能选择一个broker。

6)选择生产模式,RocketMQ是一个开源的分布式消息中间件,它支持两种消息生产模式:有序和无序。

有序消息生产模式(Ordered Message)是指按照特定规则将消息发送到相同的Message Queue中,并且确保消息在消费者端按照相同的顺序进行消费。这种模式适用于那些需要严格按照消息顺序进行处理的场景,比如订单处理、流程审批等。 无序消息生产模式(Unordered Message)是指消息发送到不同的Message Queue中,每个Queue都是独立的。消费者可以并行地从多个Queue中消费消息,而无需关心消息的顺序。这种模式适用于那些不需要严格按照消息顺序处理的场景,比如日志收集、异步通知等。

需要注意的是,无论是有序还是无序消息生产模式,RocketMQ都提供了高可靠性的消息传输和存储,并支持水平扩展和高吞吐量的特性。根据具体的业务需求,选择适合的消息生产模式能够更好地满足应用的要求。

7)选择主题的读写权限,支持读写、只读、只写3类权限。

6、 完成主题信息填写后,保存确认即可新增主题。

7、 若希望批量创建主题,可点击【批量创建】按钮

批量创建

注意:输入的主题名不要带空格等特殊字符。

通过上传csv文件,批量创建主题。格式:点击【主题模板】按钮下载。

主题模板

批量上传主题的模板,必须使用模板,才能够上传成功,模板格式如下:

yS4ZCAJasucGoJMSKnN0xQ.png



【本文地址】


今日新闻


推荐新闻


CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3